package com.hsc.www.reSend.core.delayedQueue;

import java.util.Collection;

public interface CapillaryDelayedQueueFactory {
    /**
     * 挑选合适的延迟队列
     * @param delayedTime 延迟时间 单位：秒
     */
    CapillaryDelayedQueue pick(Integer delayedTime);
    /**
     * 获取所有的延迟队列
     */
    Collection<CapillaryDelayedQueue> totalQueues();

}
